///*
// *  Copyright 2020-2021 Li Fei
// *
// *  Licensed under the Apache License, Version 2.0 (the "License");
// *  you may not use this file except in compliance with the License.
// *  You may obtain a copy of the License at
// *
// *  http://www.apache.org/licenses/LICENSE-2.0
// *
// *  Unless required by applicable law or agreed to in writing, software
// *  distributed under the License is distributed on an "AS IS" BASIS,
// *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// *  See the License for the specific language governing permissions and
// *  limitations under the License.
// */
//package com.pengshun.modules.quartz.service.impl;
//
//import cn.hutool.core.util.IdUtil;
//import com.pengshun.modules.common.*;
//import com.pengshun.modules.quartz.utils.QuartzManage;
//import lombok.RequiredArgsConstructor;
//import com.pengshun.modules.quartz.domain.QuartzJob;
//import com.pengshun.modules.quartz.domain.QuartzLog;
//import com.pengshun.modules.quartz.repository.QuartzJobRepository;
//import com.pengshun.modules.quartz.repository.QuartzLogRepository;
//import com.pengshun.modules.quartz.service.QuartzJobService;
//import com.pengshun.modules.quartz.service.dto.JobQueryCriteria;
//import org.apache.commons.lang3.StringUtils;
//import org.quartz.CronExpression;
//import org.springframework.data.domain.Pageable;
//import org.springframework.scheduling.annotation.Async;
//import org.springframework.stereotype.Service;
//import org.springframework.transaction.annotation.Transactional;
//import javax.servlet.http.HttpServletResponse;
//import java.io.IOException;
//import java.util.*;
//
///**
// * @author Li Fei
// * @date 2020年10月10日
// */
//@RequiredArgsConstructor
//@Service(value = "quartzJobService")
//public class QuartzJobServiceImpl implements QuartzJobService {
//
//    private final QuartzJobRepository quartzJobRepository;
//    private final QuartzLogRepository quartzLogRepository;
//    private final QuartzManage quartzManage;
//    private final RedisUtils redisUtils;
//
//    @Override
//    public Object queryAll(JobQueryCriteria criteria, Pageable pageable){
//        return PageUtil.toPage(quartzJobRepository.findAll((root, criteriaQuery, criteriaBuilder) -> QueryHelp.getPredicate(root,criteria,criteriaBuilder),pageable));
//    }
//
//    @Override
//    public Object queryAllLog(JobQueryCriteria criteria, Pageable pageable){
//        return PageUtil.toPage(quartzLogRepository.findAll((root, criteriaQuery, criteriaBuilder) -> QueryHelp.getPredicate(root,criteria,criteriaBuilder),pageable));
//    }
//
//    @Override
//    public List<QuartzJob> queryAll(JobQueryCriteria criteria) {
//        return quartzJobRepository.findAll((root, criteriaQuery, criteriaBuilder) -> QueryHelp.getPredicate(root,criteria,criteriaBuilder));
//    }
//
//    @Override
//    public List<QuartzLog> queryAllLog(JobQueryCriteria criteria) {
//        return quartzLogRepository.findAll((root, criteriaQuery, criteriaBuilder) -> QueryHelp.getPredicate(root,criteria,criteriaBuilder));
//    }
//
//    @Override
//    public QuartzJob findById(Long id) {
//        QuartzJob quartzJob = quartzJobRepository.findById(id).orElseGet(QuartzJob::new);
//        ValidationUtil.isNull(quartzJob.getId(),"QuartzJob","id",id);
//        return quartzJob;
//    }
//
//    @Override
//    @Transactional(rollbackFor = Exception.class)
//    public void create(QuartzJob resources) {
//        if (!CronExpression.isValidExpression(resources.getCronExpression())){
//            throw new BadRequestException("cron表达式格式错误");
//        }
//        resources = quartzJobRepository.save(resources);
//        quartzManage.addJob(resources);
//    }
//
//    @Override
//    @Transactional(rollbackFor = Exception.class)
//    public void update(QuartzJob resources) {
//        if (!CronExpression.isValidExpression(resources.getCronExpression())){
//            throw new BadRequestException("cron表达式格式错误");
//        }
//        if(StringUtils.isNotBlank(resources.getSubTask())){
//            List<String> tasks = Arrays.asList(resources.getSubTask().split("[,，]"));
//            if (tasks.contains(resources.getId().toString())) {
//                throw new BadRequestException("子任务中不能添加当前任务ID");
//            }
//        }
//        resources = quartzJobRepository.save(resources);
//        quartzManage.updateJobCron(resources);
//    }
//
//    @Override
//    public void updateIsPause(QuartzJob quartzJob) {
//        if (quartzJob.getIsPause()) {
//            quartzManage.resumeJob(quartzJob);
//            quartzJob.setIsPause(false);
//        } else {
//            quartzManage.pauseJob(quartzJob);
//            quartzJob.setIsPause(true);
//        }
//        quartzJobRepository.save(quartzJob);
//    }
//
//    @Override
//    public void execution(QuartzJob quartzJob) {
//        quartzManage.runJobNow(quartzJob);
//    }
//
//    @Override
//    @Transactional(rollbackFor = Exception.class)
//    public void delete(Set<Long> ids) {
//        for (Long id : ids) {
//            QuartzJob quartzJob = findById(id);
//            quartzManage.deleteJob(quartzJob);
//            quartzJobRepository.delete(quartzJob);
//        }
//    }
//
//    @Async
//    @Override
//    @Transactional(rollbackFor = Exception.class)
//    public void executionSubJob(String[] tasks) throws InterruptedException {
//        for (String id : tasks) {
//            QuartzJob quartzJob = findById(Long.parseLong(id));
//            // 执行任务
//            String uuid = IdUtil.simpleUUID();
//            quartzJob.setUuid(uuid);
//            // 执行任务
//            execution(quartzJob);
//            // 获取执行状态，如果执行失败则停止后面的子任务执行
//            Boolean result = (Boolean) redisUtils.get(uuid);
//            while (result == null) {
//                // 休眠5秒，再次获取子任务执行情况
//                Thread.sleep(5000);
//                result = (Boolean) redisUtils.get(uuid);
//            }
//            if(!result){
//                redisUtils.del(uuid);
//                break;
//            }
//        }
//    }
//
//    @Override
//    public void download(List<QuartzJob> quartzJobs, HttpServletResponse response) throws IOException {
//        List<Map<String, Object>> list = new ArrayList<>();
//        for (QuartzJob quartzJob : quartzJobs) {
//            Map<String,Object> map = new LinkedHashMap<>();
//            map.put("任务名称", quartzJob.getJobName());
//            map.put("Bean名称", quartzJob.getBeanName());
//            map.put("执行方法", quartzJob.getMethodName());
//            map.put("参数", quartzJob.getParams());
//            map.put("表达式", quartzJob.getCronExpression());
//            map.put("状态", quartzJob.getIsPause() ? "暂停中" : "运行中");
//            map.put("描述", quartzJob.getDescription());
//            map.put("创建日期", quartzJob.getCreateTime());
//            list.add(map);
//        }
//        FileUtil.downloadExcel(list, response);
//    }
//
//    @Override
//    public void downloadLog(List<QuartzLog> queryAllLog, HttpServletResponse response) throws IOException {
//        List<Map<String, Object>> list = new ArrayList<>();
//        for (QuartzLog quartzLog : queryAllLog) {
//            Map<String,Object> map = new LinkedHashMap<>();
//            map.put("任务名称", quartzLog.getJobName());
//            map.put("Bean名称", quartzLog.getBeanName());
//            map.put("执行方法", quartzLog.getMethodName());
//            map.put("参数", quartzLog.getParams());
//            map.put("表达式", quartzLog.getCronExpression());
//            map.put("异常详情", quartzLog.getExceptionDetail());
//            map.put("耗时/毫秒", quartzLog.getTime());
//            map.put("状态", quartzLog.getIsSuccess() ? "成功" : "失败");
//            map.put("创建日期", quartzLog.getCreateTime());
//            list.add(map);
//        }
//        FileUtil.downloadExcel(list, response);
//    }
//}
